package com.kk.rabbitmq.consumer;

import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;

@Component
public class RabbimtMQListener {
//    @RabbitListener(queues = "boot_queue")
//    public void ListenerQueue(Message message){
//        System.out.println ("boot_queue"+new String ( message.getBody () ) );
//    }
//
//    @RabbitListener(queues = "boot_queue_topic")
//    public void ListenerQueueTopic(Message message){
//        System.out.println ("boot_queue"+new String ( message.getBody () ) );
//    }

    @RabbitListener(queues = "test_queue_confirm")
    public void ListenerQueueTopic2(Message message){
        System.out.println ("test_queue_confirm"+new String ( message.getBody () ) );
    }
}
